package kafka

// Options 配置信息
type Options struct {
	Addr    []string `yaml:"Addr" json:"Addr"`
	GroupID []string `yaml:"GroupID" json:"GroupID"`
	Topic   []string `yaml:"Topic" json:"Topic"`
}

type Message struct {
	Source  string                   // 来源
	Payload []map[string]interface{} // payload中除行情价格外必须包含上报时间report_time
}

type FundMessage struct {
	Source  string
	Payload map[string]interface{} // 资金上报
}

//type NotifyMessage struct {
//	Source string
//
//}
